package com.me.chat.config;

import org.apache.activemq.command.ActiveMQQueue;
import org.apache.activemq.command.ActiveMQTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jms.config.DefaultJmsListenerContainerFactory;
import org.springframework.jms.config.JmsListenerContainerFactory;

import javax.jms.ConnectionFactory;
import javax.jms.Queue;
import javax.jms.Topic;

/**
 * activemq 消息中间件 queue 的bean 配置
 * @Author: qiu
 * @Date: 2021/3/30 10:56
 */

@Configuration
public class ActiveMQConfig {


    //es 同步操作队列
    @Bean("esAsyncQueue")
    public Queue esAsyncQueue(){
        // 该名字需要与listencer 对齐
        return new ActiveMQQueue("esAsyncQueue");
    }


    //ws 仿session 同步 消息发送
    @Bean("wsChatTopic")
    public Topic wsChatTopic(){
        return new ActiveMQTopic("wsChatTopic");
    }




    //普通配置方法的话 仅能共存一个 queue 或者 topic  所以需要额外操作 就在下方
    /**
     * 主题模式
     * @param connectionFactory
     * @return
     */
    @Bean
    public JmsListenerContainerFactory<?> jmsListenerContainerTopic(ConnectionFactory connectionFactory) {
        DefaultJmsListenerContainerFactory bean = new DefaultJmsListenerContainerFactory();
        bean.setPubSubDomain(true);
        bean.setConnectionFactory(connectionFactory);
        return bean;
    }

    /**
     * 队列模式
     * @param connectionFactory
     * @return
     */

    @Bean
    public JmsListenerContainerFactory<?> jmsListenerContainerQueue(ConnectionFactory connectionFactory) {
        DefaultJmsListenerContainerFactory bean = new DefaultJmsListenerContainerFactory();
        bean.setConnectionFactory(connectionFactory);
        return bean;
    }
}
